package com.competition.web.admin.queue;

import java.util.concurrent.Semaphore;

/**
 * 消息队列常量
 * 
 * @author 111
 *
 */
public class MsgQueueConstant {

	/**
	 * 最大队列数量
	 */
	public final static int MAX_QUEUE = 1000;

	/**
	 * 队列中最少成员数
	 */
	public final static int MIN_Count = 10;

	/**
	 * 生产者信号量 锁，用于系统消息挂起和通知
	 */
	public static Semaphore producerSemaphore = new Semaphore(1);

	/**
	 * 消费者信号量 锁，用于系统消息挂起和通知
	 */
	public static Semaphore cosumerSemaphore = new Semaphore(0);

}
